package com.arica.mq.consumer.listener;

import lombok.Data;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;

import java.util.List;

@Data
//@ToString
//@Component("mQConsumerProperties")
//@ConfigurationProperties(prefix = "rocketmq")
public abstract class BaseMQConsumerProperties {

    private String nameSrvAddr;

//    @Value("${rocketmq.consumer.group}")
    private String group;
//    @Value("${rocketmq.consumer.consumeThreadNums}")
    private Integer consumeThreadNums;
//    @Value("${rocketmq.consumer.maxReconsumeTimes}")
    private Integer maxReconsumeTimes;
    private String env;
    private List<String> topicList;
    private MessageModel messageModel = MessageModel.BROADCASTING;

    public abstract boolean isOnOff();

}
